package com.zlsy.springbootdemo.rabbitmq.stream;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author zhouliang
 * @date 2020/12/10 14:44
 */
public interface Source {

  String X_DEATH_OUTPUT = "output";

  String PARTITION_OUTPUT = "partition_output";

  String ORDINARY_OUTPUT = "ordinary_output";

  @Output(X_DEATH_OUTPUT)
  MessageChannel xDeathOutput();

  @Output(PARTITION_OUTPUT)
  MessageChannel partitionOutput();

  @Output(ORDINARY_OUTPUT)
  MessageChannel ordinaryOut();
}
